Node / ReticulumProjects / MeshChatX.git / files / meshchatx / src / backend / storage_lock.py

Displaying Raw • Download

T8b949e# SPDX-License-Identifier: 0BSD

Tff7b72import T7ee787atexit

Tff7b72import T7ee787os

Tff7b72import T7ee787sys

Tff7b72class T56d364StorageLockErrorTb4b4b4(Tf85149OSErrorTb4b4b4)Tb4b4b4:

Tff7b72pass

Tff7b72class T56d364StorageLockTb4b4b4:

Tff7b72def Tff7b72__init__Tb4b4b4(Tff7b72selfTb4b4b4, Te6edf3storage_dirTb4b4b4: Tffa657strTb4b4b4)Tb4b4b4:

Tff7b72selfTff7b72.Td2a8ffstorage_dir Tff7b72= Te6edf3osTff7b72.Td2a8ffpathTff7b72.Td2a8ffabspathTb4b4b4(Te6edf3storage_dirTb4b4b4)

Tff7b72selfTff7b72.Td2a8fflock_path Tff7b72= Te6edf3osTff7b72.Td2a8ffpathTff7b72.Td2a8ffjoinTb4b4b4(Tff7b72selfTff7b72.Td2a8ffstorage_dirTb4b4b4, Ta5d6ff"Ta5d6ff.meshchatx.lockTa5d6ff"Tb4b4b4)

Tff7b72selfTff7b72.Td2a8ff_handle Tff7b72= Tff7b72None

Tff7b72def Td2a8ffacquireTb4b4b4(Tff7b72selfTb4b4b4) Tff7b72-Tff7b72> Tff7b72NoneTb4b4b4:

Te6edf3osTff7b72.Td2a8ffmakedirsTb4b4b4(Tff7b72selfTff7b72.Td2a8ffstorage_dirTb4b4b4, Te6edf3exist_okTff7b72=Tff7b72TrueTb4b4b4)

Tff7b72selfTff7b72.Td2a8ff_handle Tff7b72= Tffa657openTb4b4b4(Tff7b72selfTff7b72.Td2a8fflock_pathTb4b4b4, Ta5d6ff"Ta5d6ffa+bTa5d6ff"Tb4b4b4)

Tff7b72tryTb4b4b4:

Tff7b72if Te6edf3sysTff7b72.Td2a8ffplatform Tff7b72== Ta5d6ff"Ta5d6ffwin32Ta5d6ff"Tb4b4b4:

Tff7b72import T7ee787msvcrt

Tff7b72selfTff7b72.Td2a8ff_handleTff7b72.Td2a8ffseekTb4b4b4(T79c0ff0Tb4b4b4)

Te6edf3msvcrtTff7b72.Td2a8fflockingTb4b4b4(Tff7b72selfTff7b72.Td2a8ff_handleTff7b72.Td2a8fffilenoTb4b4b4(Tb4b4b4)Tb4b4b4, Te6edf3msvcrtTff7b72.Td2a8ffLK_NBLCKTb4b4b4, T79c0ff1Tb4b4b4)

Tff7b72elseTb4b4b4:

Tff7b72import T7ee787fcntl

Te6edf3fcntlTff7b72.Td2a8ffflockTb4b4b4(Tff7b72selfTff7b72.Td2a8ff_handleTff7b72.Td2a8fffilenoTb4b4b4(Tb4b4b4)Tb4b4b4, Te6edf3fcntlTff7b72.Td2a8ffLOCK_EX Tff7b72| Te6edf3fcntlTff7b72.Td2a8ffLOCK_NBTb4b4b4)

Tff7b72except Tf85149OSError Tff7b72as Te6edf3excTb4b4b4:

Tff7b72selfTff7b72.Td2a8ff_handleTff7b72.Td2a8ffcloseTb4b4b4(Tb4b4b4)

Tff7b72selfTff7b72.Td2a8ff_handle Tff7b72= Tff7b72None

Tff7b72raise Te6edf3StorageLockErrorTb4b4b4(

Ta5d6fffTa5d6ff"Ta5d6ffAnother MeshChatX instance is already using storage at Tffd700{Tff7b72selfTff7b72.Td2a8ffstorage_dirTffd700}Ta5d6ff"Tb4b4b4,

Tb4b4b4) Tff7b72from T7ee787exc

Tff7b72selfTff7b72.Td2a8ff_handleTff7b72.Td2a8ffseekTb4b4b4(T79c0ff0Tb4b4b4)

Tff7b72selfTff7b72.Td2a8ff_handleTff7b72.Td2a8fftruncateTb4b4b4(Tb4b4b4)

Tff7b72selfTff7b72.Td2a8ff_handleTff7b72.Td2a8ffwriteTb4b4b4(Tffa657strTb4b4b4(Te6edf3osTff7b72.Td2a8ffgetpidTb4b4b4(Tb4b4b4)Tb4b4b4)Tff7b72.Td2a8ffencodeTb4b4b4(Tb4b4b4)Tb4b4b4)

Tff7b72selfTff7b72.Td2a8ff_handleTff7b72.Td2a8ffflushTb4b4b4(Tb4b4b4)

Te6edf3atexitTff7b72.Td2a8ffregisterTb4b4b4(Tff7b72selfTff7b72.Td2a8ffreleaseTb4b4b4)

Tff7b72def Td2a8ffreleaseTb4b4b4(Tff7b72selfTb4b4b4) Tff7b72-Tff7b72> Tff7b72NoneTb4b4b4:

Tff7b72if Tff7b72selfTff7b72.Td2a8ff_handle Tff7b72is Tff7b72NoneTb4b4b4:

Tff7b72return

Tff7b72tryTb4b4b4:

Tff7b72if Te6edf3sysTff7b72.Td2a8ffplatform Tff7b72== Ta5d6ff"Ta5d6ffwin32Ta5d6ff"Tb4b4b4:

Tff7b72import T7ee787msvcrt

Tff7b72selfTff7b72.Td2a8ff_handleTff7b72.Td2a8ffseekTb4b4b4(T79c0ff0Tb4b4b4)

Te6edf3msvcrtTff7b72.Td2a8fflockingTb4b4b4(Tff7b72selfTff7b72.Td2a8ff_handleTff7b72.Td2a8fffilenoTb4b4b4(Tb4b4b4)Tb4b4b4, Te6edf3msvcrtTff7b72.Td2a8ffLK_UNLCKTb4b4b4, T79c0ff1Tb4b4b4)

Tff7b72elseTb4b4b4:

Tff7b72import T7ee787fcntl

Te6edf3fcntlTff7b72.Td2a8ffflockTb4b4b4(Tff7b72selfTff7b72.Td2a8ff_handleTff7b72.Td2a8fffilenoTb4b4b4(Tb4b4b4)Tb4b4b4, Te6edf3fcntlTff7b72.Td2a8ffLOCK_UNTb4b4b4)

Tff7b72except Tf85149OSErrorTb4b4b4:

Tff7b72pass

Tff7b72tryTb4b4b4:

Tff7b72selfTff7b72.Td2a8ff_handleTff7b72.Td2a8ffcloseTb4b4b4(Tb4b4b4)

Tff7b72except Tf85149OSErrorTb4b4b4:

Tff7b72pass

Tff7b72selfTff7b72.Td2a8ff_handle Tff7b72= Tff7b72None